package top.ucat.boots.example.rocketmq.consumer.config;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;

/**
 * @Auther: Jun
 * @Date: 2019/8/21 15:28
 * @Description:
 */
public interface MySource {

    String INPUT = "input";

    @Input("input")
    SubscribableChannel input();


}
